package demo.delay;

import org.apache.kafka.clients.consumer.KafkaConsumer;

import java.lang.reflect.Method;


public class KafkaDelayConsumerContainer {

    /**
     * 消费逻辑方法所属bean
     */
    private Object bean;

    /**
     * 业务消费方法
     */
    private Method method;

    /**
     * 注解详情
     */
    private KafkaDelayListener kafkaDelayListener;

    /**
     * 消费者
     */
    private KafkaConsumer<String,String> consumer;

    private KafkaDltMessageHandler kafkaDltMessageHandler;

    public KafkaDelayConsumerContainer(Object bean, Method method, KafkaDelayListener kafkaDelayListener) {
        this.bean = bean;
        this.method = method;
        this.kafkaDelayListener = kafkaDelayListener;
    }

    public KafkaDelayListener getKafkaDelayListener() {
        return kafkaDelayListener;
    }

    public void setKafkaDelayListener(KafkaDelayListener kafkaDelayListener) {
        this.kafkaDelayListener = kafkaDelayListener;
    }

    public Object getBean() {
        return bean;
    }

    public Method getMethod() {
        return method;
    }

    public KafkaConsumer<String, String> getConsumer() {
        return consumer;
    }

    public void setConsumer(KafkaConsumer<String, String> consumer) {
        this.consumer = consumer;
    }

    public KafkaDltMessageHandler getKafkaDltMessageHandler() {
        return kafkaDltMessageHandler;
    }

    public void setKafkaDltMessageHandler(KafkaDltMessageHandler kafkaDltMessageHandler) {
        this.kafkaDltMessageHandler = kafkaDltMessageHandler;
    }
}
